var mysql = require('mysql');
var $sql = require('./sqlMapping')

var pool = mysql.createPool({
    host     : '127.0.0.1',
    user     : 'root',
    password : 'ly1207',
    database : 'demo'
});
// 向前台返回JSON方法的简单封装
var jsonWrite = function (res, ret) {
    if(typeof ret === 'undefined') {
        res.json({
            code:'1',
            msg: '操作失败'
        });
    } else {
        res.json(ret);
    }
};

module.exports = {
    write: function (req, res, next) {
        pool.getConnection(function (err, connection) {
            // 获取前台页面传过来的参数
            var param = req.body;
            var date = new Date();
            // 建立连接，向表中插入值
           
            connection.query($sql.insert, [param.title, param.description, param.content,date], function (err, result) {
                if (result) {
                    result = {
                        code: 200,
                        msg: '增加成功'
                    };
                }

                // 以json形式，把操作结果返回给前台页面
                jsonWrite(res, result);

                // 释放连接
                connection.release();
            });
        });
    },
    tag: function (req, res, next) {
        pool.getConnection(function (err, connection) {
            // 获取前台页面传过来的参数
            var param = req.body;
            var date = new Date();
            // 建立连接，向表中插入值
            connection.query($sql.insertTag, [param.name, param.desc, date], function (err, result) {
                if (result) {
                    result = {
                        code: 200,
                        msg: '增加成功'
                    };
                }
                // 以json形式，把操作结果返回给前台页面
                jsonWrite(res, result);
                // 释放连接
                connection.release();
            });
        });
    }
}